# -*- encoding:utf-8 -*-
from mycelery.main import app   #导入main中实例的主程序
from luffyapi.libs.yuntongxun.sms import YunTongXin     #导入发送短信的第三方sdk

# 由于celery的main.py中已经导入了django的配置并且初始化django，让celery管理django的应用：luffy
# 所以这里直接应用django的日志输出管理
import logging,json
log = logging.getLogger("django")

@app.task(name="send_sms")  # 配置之后就可以让celery实例的主程序识别 name设置任务名称 "send_sms"
def send_sms(mobile,sms_code):
    """发送短信"""

    ccp = YunTongXin()
    ret = json.loads(ccp.run(mobile, sms_code))  # 官方是分钟级别 需要转换时间并且//60拿到整数
    if ret.get('statusCode') != "000000":
        log.error("用户手机号发送短信失败,手机号:%s" % (mobile))
        # 失败也无需返回，记录到日志中即可
        # return Response({"message": "发送短信失败！"}, status=status.HTTP_500_INTERNAL_SERVER_ERROR)




































